package com.microlearning.common.rabbitmq.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

/**
 * Topic(通配符订阅)交换机：与Direct相似，路由key可以使用通配符
 * 总结：
 *      1、Topic交换机接收的消息路由key必须是多个单词，以.分割
 *      2、Topic交换机与队列绑定时的路由key可以指定统配符
 *      3、#：代表0个或多个词
 *      4、*：代表1个词
 */
@Service
public class TopicConsumer {

    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.topic.queue1")
    public String pullMessageQueue1(String message) {
        return message;
    }
    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.topic.queue2")
    public String pullMessageQueue2(String message) {
        return message;
    }

}
